package org.chnxi.study.messagequeue.kafka.comsumer;

import org.apache.kafka.clients.consumer.ConsumerRecords;

public interface ConsumeMsgProcessor<K,V> {

    public boolean consume(ConsumerRecords<K, V> consumerRecords);

}
